package com.youxin.dataStream.custormSink;

import org.apache.flink.streaming.api.functions.sink.SinkFunction;

public class ParalleSink implements SinkFunction<String> {
    @Override
    public void invoke(String value, Context context) throws Exception {

    }
}
